# 入口文件
import os

from celery import Celery

# 引入django配置
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'jt31.settings')
# 创建celery  应用名
app = Celery("jutong31")
# 导入消息队列 结果队列的配置
app.config_from_object("celery_tasks.celery_config")
# 导入邮箱任务
app.autodiscover_tasks(["celery_tasks.email"])